package com.ht.api.bigtask.impl.qywx;

import javax.sql.DataSource;

import com.ht.api.bigtask.BaseBigTask;
import com.ht.api.db.DbConfig;
import com.ht.api.db.Entity;
import com.ht.api.db.StreamLoadConfig;
import com.ht.api.service.TransferService;

import cn.hutool.json.JSONObject;
import lombok.extern.slf4j.Slf4j;

/**
 * 企微初始化：拉取离职成员列表
 * @author asq
 * @createTime 2025年3月27日 11:12:03
 */
@Slf4j
public class GetUnassignedList extends BaseBigTask {

	@Override
	protected void doExecute(String appId, JSONObject context, Entity bean) {
		DataSource ds = getTenantDs(appId);
		StreamLoadConfig streamConfig = DbConfig.getStreamLoadConfigByDataSource(ds);
		long tenantId = DbConfig.getTenantId(ds);
		TransferService.refreshUnassignedList(ds, streamConfig, tenantId);
	}
}
